package com.sugon.ww

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}


object RddDemo {

  def main(args: Array[String]): Unit = {

    val config: SparkConf = new SparkConf().setMaster("local[*]").setAppName("rdd")

    val sc = new SparkContext(config)

    // 内存中创建 makeRDD
    val listRDD: RDD[Int] = sc.makeRDD(List(1, 2, 3, 4),2)

    //    val arrayRDD: RDD[Int] = sc.parallelize(Array(1,2,3,4))

    //3 外部存储中创建
//    val lines: RDD[String] = sc.textFile("in")

    listRDD.saveAsTextFile("output")

    //    listRDD.collect().foreach(println)
  }
}
